import logging
from preprocessor.preprocessor import EventPreprocessor

_LOGGER = logging.getLogger(__name__)


class OfflineCalculationEventPreprocessor(EventPreprocessor):
    """OfflineCalculation(离线计算埋点) Preprocessor """

    def __init__(self, topic, add_prefix=True):
        super().__init__(topic, add_prefix)

    def handle(self, event_data):
        self.event_data = event_data
        self.add_event_prefix()
        return self.event_data
